package com.iamteer.jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.beanutils.BeanUtils;

import com.iamteer.utils.JdbcUtil;

/**
 * 通用的 dao，自己写的所有的 dao 都继承此类；
 * 此类定义了 2 个通用的方法：
 * 1. 更新
 * 2. 查询
 * @author Chuck
 *
 */
public class BaseDao {
	private Connection con;
	private PreparedStatement pstmt;
	private ResultSet rs;
	
	/**
	 * 更新的通用方法
	 * @param sql	更新的 sql 语句（update/insert/delete）
	 * @param paramsValue	sql 语句中占位符对应的值（如果没有占位符，传入 null）
	 */
	public void update(String sql, Object[] paramsValue) {
		try {
			// 获取连接
			con = JdbcUtil.getConnection();
			// 创建执行命令的 stmt 对象
			pstmt = con.prepareStatement(sql);
			// 参数元数据：得到占位符参数的个数
			int count = pstmt.getParameterMetaData().getParameterCount();
			// 设置占位符参数的值
			if (paramsValue != null && paramsValue.length > 0) {
				// 循环给参数赋值
				for(int i=0;i<count;i++){
					pstmt.setObject(i+1, paramsValue[i]);
				}
			}
			// 执行更新
			pstmt.executeUpdate();
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			JdbcUtil.closeAll(con, pstmt, null);
		}
	}
	
	/**
	 * 查询的通用方法
	 * @param sql
	 * @param paramsValue
	 * @param clazz
	 * @return
	 */
	public <T> List<T> query(String sql, Object[] paramsValue, Class<T> clazz) {
		try {
			List<T> list = new ArrayList<T>();
			// 要封装的对象
			T t = null;
			
			// 1. 获取连接
			con = JdbcUtil.getConnection();
			// 2. 创建 stmt 对象
			pstmt = con.prepareStatement(sql);
			// 3. 获取占位符参数的个数，并设置参数
			int count = pstmt.getParameterMetaData().getParameterCount();
			if (paramsValue != null && paramsValue.length > 0) {
				for (int i = 0; i < count; i++) {
					pstmt.setObject(i+1, paramsValue[i]);
				}
			}
			// 4. 执行查询
			rs = pstmt.executeQuery();
			// 5. 获取结果集元数据
			ResultSetMetaData rsmd = rs.getMetaData();
			// ----> 获取列个数
			int columnCount = rsmd.getColumnCount();
			// 6. 遍历结果rs
			while (rs.next()) {
				t = clazz.newInstance();
				// 7. 遍历每一行的每一列，同时封装数据
				for (int i = 0; i < columnCount; i++) {
					// 获取每一列的名称
					String columnName = rsmd.getColumnName(i + 1);
					// 获取每一列的值
					Object value = rs.getObject(columnName);
					
					// 封装：设置对象的属性值
					BeanUtils.copyProperty(t, columnName, value);
				}
				list.add(t);
			}
			
			return list;
		} catch (Exception e) {
			throw new RuntimeException(e);
		} finally {
			JdbcUtil.closeAll(con, pstmt, rs);
		}
		
	}
}
